// Copyright 2022 marcello<volibearw@gmail.com>. All rights reserved.
package main

import (
	"log"
)

func test(param *CLIParam) {
	var (
		err    error
		tables map[string][]Columns // 所有表数据
	)

	log.Println("连接数据库...")
	if err = connect(param); err != nil {
		return
	}
	log.Println("连接数据库成功")

	log.Printf("开始获取 %s 的数据\n", param.Schema)
	var columns []Columns
	if columns, err = queryAllTable(param.Schema); err != nil {
		log.Printf("开始获取 %s 的数据失败;err: %v\n", param.Schema, err)
		return
	}

	log.Printf("开始转换数据类型...\n")
	tables = analysisColumns(columns)

	generateModel(param, tables)

	generateProtobuf3(param, tables)

	log.Printf("执行成功")
}
